<?xml version="1.0"?>
<component name="org.nuxeo.runtime.stream.service.override">

  <require>org.nuxeo.runtime.stream.service</require>

  <documentation>

    The component allows to register log configurations and Log and Stream processors.
  

  </documentation>
  <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
    <streamProcessor class="org.nuxeo.runtime.stream.StreamMetricsProcessor" enabled="true" name="metrics">
      <!-- To handle a MSK rolling upgrade we need 30min retries -->
      <policy continueOnFailure="false" delay="15s" maxDelay="120s" maxRetries="18" name="default"/>
      <stream codec="avro" name="input/null" partitions="1"/>
      <computation concurrency="1" name="stream/metrics"/>
    </streamProcessor>
  </extension>

</component>
